#include "app_mqtt.h"
#include "log.h"
#include "unistd.h"

static int callback_func(char *arg){
    log_info("recv data:%s",arg);
    return 0;
}

int main(int argc, char const *argv[])
{

    // 1.初始化mqtt
    app_mqtt_init();

    // 2.发送数据
    app_mqtt_send("hello world!!");

    // 3.接收数据
    // 把处理接收数据的方法注册给队列模块，一旦有数据接收，回调该函数
    app_mqtt_register_recv_callback(callback_func);

    sleep(1000);

    // 4.销毁mqtt
    app_mqtt_destroy();
    
    return 0;
}
